
/**
* @Title: Consumer.java
* @Package com.leetone
* @Description: 【】
* @date 2018年9月1日 下午3:25:32
* @version V1.0
* @Company: 上海未泰信息技术有限公司
* @author:[谭磊][leetone123@163.com]
*/

package com.leetone;

import java.util.concurrent.TransferQueue;

/**
* @ClassName: Consumer
* @Description: 【消费者，LinkedTransferQueue测试】
* @date 2018年9月1日 下午3:25:32
* @Company: 上海未泰信息技术有限公司
* @author:[谭磊][leetone123@163.com]
*/

public class Consumer implements Runnable{
	private final TransferQueue<String> queue;
	public Consumer(TransferQueue<String> queue) {
		this.queue = queue;
	}
	@Override
	public void run() {
		try {
			System.out.println("Consumer:\t"+Thread.currentThread().getName()+queue.take());
		} catch (InterruptedException e) {
			// TODO Auto-generated catch block
			e.printStackTrace();
		}
	}
}
